9399b60e6d83d549105783e60c2d6a6325c2af88,src/main/java/com/continuuity/data/operation/executor/remote/TOperationExecutorImpl.java,TOperationExecutorImpl,dequeue,#TQueueDequeue#,223
Before Change
DequeueResult result = this.opex.execute(queueDequeue);
if (Log.isDebugEnabled())
Log.debug("QueueDequeue result: " + result);
return wrap(result);
}
// getGroupId always returns a long and cannot be null
After Change
if (Log.isDebugEnabled())
Log.debug("QueueDequeue result: " + result);
TDequeueResult tResult = wrap(result);
helper.success();
return tResult;
}
// getGroupId always returns a long and cannot be null